from pyspark import SparkConf, SparkContext

if __name__ == '__main__':
    # 构建SparkConf对象
    conf = SparkConf().setAppName("test").setMaster("local[*]")
    # 构建SparkContext执行环境入口对象
    sc = SparkContext(conf=conf)

    rdd = sc.parallelize([("a", 1), ("b", 2), ("c", 3), ("d", 10)])

    rdd = rdd.mapValues(lambda v: v*10)
    """
        mapValues方法，针对二元元组的value进行map操作
        f: (V) -> U
        接收一个参数：任意类型
        返回一个参数：任意类型
    """

    print(rdd.collect())